type net/http/internal/http2.stream
29 uses
net/http/internal/http2 (current package)
server.go#L269: streams: make(map[uint32]*stream),
server.go#L445: streams map[uint32]*stream
server.go#L512: type stream struct {
server.go#L546: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L1002: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1572: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1814: func (st *stream) isPushed() bool {
server.go#L1820: func (st *stream) endStream() {
server.go#L1836: func (st *stream) copyTrailersToHandlerRequest() {
server.go#L1847: func (st *stream) onReadTimeout() {
server.go#L1857: func (st *stream) onWriteTimeout() {
server.go#L2008: func (st *stream) processTrailerHeaders(f *MetaHeadersFrame) error {
server.go#L2081: func (sc *serverConn) newStream(id, pusherID uint32, state streamState, priority PriorityParam) *stream {
server.go#L2088: st := &stream{
server.go#L2116: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *ServerRequest, error) {
server.go#L2197: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *ServerRequest, error) {
server.go#L2229: func (sc *serverConn) newResponseWriter(st *stream) *responseWriter {
server.go#L2250: func (sc *serverConn) scheduleHandler(st *stream, rw *responseWriter, req *ServerRequest, handler func(*ResponseWriter, *ServerRequest)) error {
server.go#L2347: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2379: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2389: st *stream
server.go#L2396: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2406: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2417: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2422: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2445: stream *stream
server.go#L2493: stream *stream
server.go#L3058: parent *stream
writesched.go#L59: stream *stream